home *** CD-ROM | disk | FTP | other *** search
/ Amiga Developer CD 2.1 / Amiga Developer CD v2.1.iso / Reference / DevCon / Milan_1991 / Devcon91.2 / Network / Socket / examples / ping.c < prev    next >
Encoding:
C/C++ Source or Header  |  1992-09-01  |  12.8 KB  |  491 lines
  1. /* ---------------------------------------------------------------------------------
  2.  * PING.C
  3.  *
  4.  * $Locker:
  5.  *
  6.  * $Id:
  7.  *
  8.  * $Revision:
  9.  *
  10.  * $Header:
  11.  *
  12.  *-----------------------------------------------------------------------------------
  13.  */
  14.  
  15. /* sample internet ping client */
  16.  
  17. /* This is an advanced sockets program that shows how to use */
  18. /* raw sockets, async I/O, and timers.  This code will only  */
  19. /* work with AmigaDOS 2.0.  To run under 1.3, simply replace */
  20. /* ReadArgs() with your own parsing code and use another     */
  21. /* timer in place of the ReadEClock() calls.                 */
  22.  
  23. /* to compile with SAS C , type
  24. "lc -cfist -v -inetinc: -fi -Lm ping.c"                      */
  25.  
  26. /* Written by Martin Hunt, Commodore-Amiga, June 1991        */
  27.  
  28. /* Parts of this program were based on code by Mike Muuss    */
  29.  
  30. /* This code is placed in the public domain */
  31.  
  32. #include <exec/types.h>
  33. #include <exec/memory.h>
  34. #include <exec/tasks.h>
  35. #include <dos/dos.h>
  36. #include <devices/timer.h>
  37. #include <stdio.h>
  38. #include <stdarg.h>
  39. #include <string.h>
  40. #include <proto/all.h>
  41.  
  42. /* shared library stuff */
  43. #include <ss/socket.h>
  44. #include <sys/ioctl.h>
  45. #include <sys/socket.h>
  46. #include <signal.h>
  47. #include <netinet/in_systm.h>
  48. #include <netinet/in.h>
  49. #include <netinet/ip.h>
  50. #include <netinet/ip_icmp.h>
  51. #include <netdb.h>
  52.  
  53.  
  54. /* get version and revision information */
  55. #include "ping_rev.h"
  56.  
  57. /* This is used with the templates to cause the version string to be */
  58. /* stored in the command.  It depends upon the command having a #include */
  59. /* of the appropriate version file to provide the value for this string */
  60. #define CMDREV  "\0$VER: " VSTRING
  61.  
  62. /* template for ReadArgs() */
  63. #define TEMPLATE    "-L/S,HOST/A,SIZE/N,COUNT/N" CMDREV
  64. #define OPT_L       0
  65. #define OPT_HOST    1
  66. #define OPT_SIZE    2
  67. #define OPT_COUNT   3
  68. #define OPT_MAX     4
  69.  
  70. #define MAXPACKET   4096    /* max packet size */
  71. struct Library *SockBase ;
  72. struct Library *TimerBase ;
  73. UBYTE buffer[MAXPACKET];
  74. struct MsgPort *timerport1=NULL;
  75. struct timerequest *timer1=NULL;
  76. u_long ntransmitted = 0, nreceived = 0;
  77. u_long tsum = 0;
  78. u_long tmin = 999999;
  79. u_long tmax = 0;
  80. u_long e_freq;
  81. UWORD ident;
  82. long size,count;
  83. BOOL loop = (BOOL)0;
  84. long return_code = RETURN_ERROR;
  85.  
  86. /* prototypes */
  87. UWORD in_cksum(UWORD *addr, int len);
  88. ULONG create_timers(void);
  89. void send_icmp(int s, struct sockaddr_in *to);
  90. char *pr_type( int t );
  91. void read_icmp(int s );
  92. void pr_pack( int cc, struct sockaddr_in *from );
  93.  
  94. void main (void)
  95. {
  96.     char *host, *hostname;
  97.     long timerevent, netevent, event;
  98.     struct RDargs *rdargs;
  99.     int s;
  100.     struct sockaddr_in to;
  101.     struct hostent *hp;
  102.     struct protoent *proto;
  103.     long true = 1;
  104.     char *toaddr = NULL;
  105.     long opts[OPT_MAX];
  106.     UWORD abort = 0;
  107.  
  108.     memset((char *)opts, 0, sizeof(opts));
  109.     rdargs = ReadArgs(TEMPLATE, opts, NULL);
  110.  
  111.     if ((SockBase = OpenLibrary( "inet:libs/socket.library", 1L ))==NULL) {
  112.         printf("Opening of socket library failed.\n");
  113.         goto exit1;
  114.     }
  115.  
  116.     /* initialize for 5 sockets */
  117.     setup_sockets( 5, &errno );
  118.  
  119.     /* process arguments */
  120.     if(opts[OPT_COUNT])
  121.         count = *(long *)opts[OPT_COUNT];
  122.     else
  123.         count = 100;
  124.  
  125.     if(opts[OPT_L])
  126.         loop = (BOOL)opts[OPT_L];
  127.     else
  128.         count = 1;
  129.  
  130.     if (!(host = (char *)opts[OPT_HOST]))
  131.         goto exit2;
  132.  
  133.     if(opts[OPT_SIZE])
  134.         size = max( *(long *)opts[OPT_SIZE], 64);
  135.     else
  136.         size = 64;
  137.  
  138.     /* zero structure */
  139.     memset( (char *)&to, '\0',sizeof(struct sockaddr_in) );
  140.  
  141.     to.sin_family = AF_INET;
  142.     to.sin_addr.s_addr = inet_addr(host);
  143.     if (to.sin_addr.s_addr == INADDR_NONE) {
  144.         hp = gethostbyname(host);
  145.         if (!hp) {
  146.             printf("Error finding host %s\n",host);
  147.             goto exit2;
  148.         }
  149.         to.sin_family = hp->h_addrtype;
  150.         memcpy((char *)&to.sin_addr, hp->h_addr, hp->h_length);
  151.         hostname = hp->h_name;
  152.         toaddr = inet_ntoa(to.sin_addr.s_addr);
  153.     } else
  154.         hostname = host;
  155.  
  156.     /* ident is used in the ICMP packet so we can tell that its ours */
  157.     ident = (UWORD)((long)FindTask(0L) & 0xFFFF);
  158.  
  159.     if ((proto = getprotobyname("icmp")) == NULL) {
  160.         printf("icmp: unknown protocol\n");
  161.         goto exit2;
  162.     }
  163.     /* open an ICMP socket */
  164.     if ((s = socket(AF_INET, SOCK_RAW, proto->p_proto)) < 0) {
  165.         printf("ping: socket: %s\n",strerror(errno));
  166.         goto exit2;
  167.     }
  168.  
  169.     /* set socket to ASYNC so we will be signaled when packets arrive */
  170.     if(s_ioctl(s, FIOASYNC, (char *)&true) < 0){
  171.         printf("ping: s_ioctl: %s\n",strerror(errno));
  172.         goto exit2;
  173.     }
  174.     /* set socket to nonblocking */
  175.     if(s_ioctl(s, FIONBIO, (char *)&true) < 0){
  176.         printf("ping: s_ioctl: %s\n",strerror(errno));
  177.         goto exit2;
  178.     }
  179.  
  180.     if(loop) {
  181.         printf("PING %s", hostname);
  182.         if (toaddr)
  183.             printf(" (%s)", toaddr);
  184.         printf(": %ld data bytes\n", size);
  185.     }
  186.  
  187.     /* setup timer.  timer1 is a 1 second timer for sending packets */
  188.  
  189.     if(create_timers()) {
  190.         printf("Error setting up timer\n");
  191.         goto exit2;
  192.     }
  193.  
  194.     timerevent = 1L << timerport1->mp_SigBit;
  195.     netevent = 1L << s_getsignal(SIGIO);
  196.  
  197.     do {
  198.         /* send ICMP echo request */
  199.         send_icmp(s,&to);
  200.         for(;;) {
  201.             /* wait for a response, timeout, or ^C */
  202.             event = Wait(netevent | timerevent | SIGBREAKF_CTRL_C);
  203.             if(event & netevent) {
  204.                 read_icmp(s);
  205.                 SetSignal(0L,netevent);
  206.                 if(!loop) {
  207.                     AbortIO((struct IORequest *)timer1);
  208.                     WaitIO((struct IORequest *)timer1);
  209.                     abort++;
  210.                     break;
  211.                 }
  212.  
  213.             }
  214.             if(event & SIGBREAKF_CTRL_C) {
  215.                 AbortIO((struct IORequest *)timer1);
  216.                 WaitIO((struct IORequest *)timer1);
  217.                 abort++;
  218.                 break;
  219.             }
  220.             if(event & timerevent) {
  221.                 AbortIO((struct IORequest *)timer1);
  222.                 WaitIO((struct IORequest *)timer1);
  223.                 SetSignal(0L, timerevent);
  224.                 break;
  225.             }
  226.         }
  227.  
  228.     } while (!abort && (ntransmitted != count) );
  229.  
  230.     if(loop) {
  231.         printf("\n----%s PING Statistics----\n", hostname );
  232.         printf("%d packets transmitted, ", ntransmitted );
  233.         printf("%d packets received, ", nreceived );
  234.         if (ntransmitted)
  235.             printf("%d%% packet loss",
  236.             (int) (((ntransmitted-nreceived)*100) / ntransmitted ) );
  237.         printf("\n");
  238.         if (nreceived)
  239.             printf("round-trip (ms)  min/avg/max = %#2.2lf/%#2.2lf/%#2.2lf\n",
  240.             (double)tmin/(double)e_freq*1000.0,
  241.             (double)(tsum*1000) / (double)(nreceived*e_freq),
  242.             (double)tmax/(double)e_freq*1000.0 );
  243.     } else
  244.         if(nreceived)
  245.             printf("%s is alive!\n",host);
  246.  
  247.     fflush(stdout);
  248.  
  249.     if (s)
  250.         s_close(s);
  251.  
  252.     if(timerport1)
  253.         DeleteMsgPort(timerport1);
  254.     if(timer1)
  255.         DeleteIORequest(timer1);
  256. exit2:
  257.     cleanup_sockets();
  258.     CloseLibrary(SockBase);
  259. exit1:
  260.     if(rdargs)
  261.         FreeArgs(rdargs);
  262.     CloseLibrary((struct Library *)DOSBase);
  263.  
  264.     exit(return_code);
  265. }
  266.  
  267. /*
  268.  *          I N _ C K S U M
  269.  *
  270.  * Checksum routine for Internet Protocol family headers (C Version)
  271.  *
  272.  */
  273. UWORD in_cksum(UWORD *addr, int len)
  274. {
  275.     register int nleft = len;
  276.     register UWORD *w = addr;
  277.     register UWORD answer;
  278.     register int sum = 0;
  279.     UWORD odd_byte = 0;
  280.  
  281.     /*
  282.      *  Our algorithm is simple, using a 32 bit accumulator (sum),
  283.      *  we add sequential 16 bit words to it, and at the end, fold
  284.      *  back all the carry bits from the top 16 bits into the lower
  285.      *  16 bits.
  286.      */
  287.     while( nleft > 1 )  {
  288.         sum += *w++;
  289.         nleft -= 2;
  290.     }
  291.  
  292.     /* mop up an odd byte, if necessary */
  293.     if( nleft == 1 ) {
  294.         *(u_char *)(&odd_byte) = *(u_char *)w;
  295.         sum += odd_byte;
  296.     }
  297.  
  298.     /*
  299.      * add back carry outs from top 16 bits to low 16 bits
  300.      */
  301.     sum = (sum >> 16) + (sum & 0xffff); /* add hi 16 to low 16 */
  302.     sum += (sum >> 16);
  303.     answer = ~sum;              /* truncate to 16 bits */
  304.     return (answer);
  305. }
  306.  
  307.  
  308. ULONG create_timers(void)
  309. {
  310.     timerport1 = CreateMsgPort();
  311.     if(timerport1 == (struct MsgPort *)0)
  312.         return (1);
  313.  
  314.     timer1 = (struct timerequest *)CreateIORequest(timerport1,(long)sizeof(struct timerequest));
  315.     if(timer1 == (struct MsgPort *)0)
  316.         return(1);
  317.  
  318.     if(OpenDevice(TIMERNAME, UNIT_VBLANK, (struct IORequest *)timer1, 0L) != 0L)
  319.         return(1);
  320.  
  321.     /* set up TimerBase so we can use ReadEClock() */
  322.     TimerBase = (struct Library *)timer1->tr_node.io_Device;
  323.  
  324.     return(0);
  325. }
  326.  
  327. /* send an ICMP echo request */
  328. /* the timestamp is written in the first 8 bytes of data */
  329.  
  330. void send_icmp(int s, struct sockaddr_in *to)
  331. {
  332.     UBYTE *datap;
  333.     struct icmp *icp = (struct icmp *) buffer;
  334.     int i;
  335.  
  336.     icp->icmp_type = ICMP_ECHO;
  337.     icp->icmp_code = 0;
  338.     icp->icmp_cksum = 0;
  339.     icp->icmp_seq = ntransmitted++;
  340.     icp->icmp_id = ident;
  341.  
  342.     /* start the 1 second timer */
  343.     timer1->tr_node.io_Command = TR_ADDREQUEST;
  344.     timer1->tr_time.tv_secs = 1L;
  345.     timer1->tr_time.tv_micro = 0L;
  346.     SendIO((struct IORequest *)timer1);
  347.  
  348.  
  349.     /* get system time and put it in first 8 bytes of data field */
  350.     /* note that we will be timing filling the packet with data  */
  351.     /* and checksumming it.                                      */
  352.  
  353.     ReadEClock((struct EClockVal *)(buffer+8));
  354.  
  355.     datap = (UBYTE *)(buffer+16);   /* skip 8 for header and 8 for timestamp */
  356.  
  357.     /* fill packet with data */
  358.     for( i=16; i<size; i++)
  359.         *datap++ = i;
  360.  
  361.     /* Compute ICMP checksum */
  362.     icp->icmp_cksum = in_cksum( (UWORD *)icp, size );
  363.  
  364.     /* send it */
  365.     i = sendto( s, buffer, size, 0, to, sizeof(struct sockaddr) );
  366.  
  367.     if( i < 0 || i != size )  {
  368.         if( i<0 )
  369.             printf("sendto: %s\n",strerror(errno));
  370.         printf("ping: wrote %ld chars, ret=%ld\n",size, i );
  371.     }
  372.  
  373. }
  374.  
  375. void read_icmp(int s)
  376. {
  377.     struct sockaddr_in from;
  378.     int fromlen = sizeof (from);
  379.     int cc;
  380.  
  381.     if ( (cc=recvfrom(s, buffer, MAXPACKET, 0, &from, &fromlen)) < 0) {
  382.         if( errno == EINTR || errno == EWOULDBLOCK){
  383.             return ;
  384.         }
  385.         printf("ping: recvfrom: %s\n",strerror(errno));
  386.         return ;
  387.     }
  388.     pr_pack( cc, &from );
  389. }
  390.  
  391.  
  392. /*
  393.  *          P R _ P A C K
  394.  *
  395.  * Print out the packet, if it came from us.  This logic is necessary
  396.  * because ALL readers of the ICMP socket get a copy of ALL ICMP packets
  397.  * which arrive ('tis only fair).  This permits multiple copies of this
  398.  * program to be run without having intermingled output (or statistics!).
  399.  */
  400. void pr_pack( int cc, struct sockaddr_in *from )
  401. {
  402.     struct ip *ip;
  403.     register struct icmp *icp;
  404.     register long *lp = (long *) buffer;
  405.     register int i;
  406.     struct EClockVal intime, *outtime;
  407.     int hlen;
  408.     u_long triptime;
  409.  
  410.  
  411.     e_freq = ReadEClock(&intime);
  412.     from->sin_addr.s_addr = ntohl( from->sin_addr.s_addr );
  413.     ip = (struct ip *)buffer;
  414.  
  415.     /* get the IP header length */
  416.     hlen = ip->ip_hl << 2;
  417.  
  418.     if (cc < hlen + ICMP_MINLEN) {
  419.         printf("packet too short (%d bytes) from %s\n", cc,
  420.                 inet_ntoa(ntohl(from->sin_addr.s_addr)));
  421.         return;
  422.     }
  423.     cc -= hlen;
  424.  
  425.     /* the ICMP packet starts after the IP header */
  426.     icp = (struct icmp *)(buffer + hlen);
  427.     if( icp->icmp_type != ICMP_ECHOREPLY )  {
  428.         printf("%d bytes from %s: ", cc,
  429.             inet_ntoa(ntohl(from->sin_addr.s_addr)));
  430.         printf("icmp_type=%d (%s)\n",
  431.             icp->icmp_type, pr_type(icp->icmp_type) );
  432.         for( i=0; i<12; i++)
  433.             printf("x%2.2x: x%8.8x\n", i*sizeof(long), *lp++ );
  434.         printf("icmp_code=%d\n", icp->icmp_code );
  435.         return;
  436.     }
  437.     if( icp->icmp_id != ident )
  438.         return;         /* 'Twas not our ECHO */
  439.  
  440.     return_code = RETURN_OK;
  441.  
  442.     outtime = (struct EClockVal *)(&icp->icmp_data[0]);
  443.     triptime = intime.ev_lo-outtime->ev_lo;
  444.  
  445.     if(loop) {
  446.         printf("%d bytes from %s: ", cc,inet_ntoa(ntohl(from->sin_addr.s_addr)));
  447.         printf("icmp_seq=%d. ", icp->icmp_seq );
  448.         printf("time=%#2.2lf ms\n", (double)triptime/(double)e_freq*1000.0 );
  449.     }
  450.  
  451.     /* update total, max, and min times */
  452.     tsum += triptime;
  453.     tmax = max(tmax,triptime);
  454.     tmin = min(tmin,triptime);
  455.  
  456.     nreceived++;
  457. }
  458.  
  459. /*
  460.  *          P R _ T Y P E
  461.  *
  462.  * Convert an ICMP "type" field to a printable string.
  463.  */
  464. char *pr_type( int t )
  465. {
  466.     static char *ttab[] = {
  467.         "Echo Reply",
  468.         "ICMP 1",
  469.         "ICMP 2",
  470.         "Dest Unreachable",
  471.         "Source Quench",
  472.         "Redirect",
  473.         "ICMP 6",
  474.         "ICMP 7",
  475.         "Echo",
  476.         "ICMP 9",
  477.         "ICMP 10",
  478.         "Time Exceeded",
  479.         "Parameter Problem",
  480.         "Timestamp",
  481.         "Timestamp Reply",
  482.         "Info Request",
  483.         "Info Reply"
  484.     };
  485.  
  486.     if( t < 0 || t > 16 )
  487.         return("OUT-OF-RANGE");
  488.  
  489.     return(ttab[t]);
  490. }
  491.